package cn.com.ytst.data.integration.components.writer.kafka;

/**
 * @ClassName KafkaWriterKey
 * @Deacription TODO
 * @Author Administrator
 * @Date 2020/1/18 0018 18:49
 * @Version 1.0
 **/
public final class KafkaWriterKey {

    public static final String KAFAK_WRITER_BOOTSTRAPSERVERS_TAG = "parameter.bootstrapservers";
    public static final String KAFAK_WRITER_TOPIC_TAG = "parameter.topic";
    public static final String KAFAK_WRITER_KEY_TAG = "parameter.key";
    public static final String KAFAK_WRITER_ATTRUE_TAG = "parameter.attrue";
    public static final String KAFAK_WRITER_TABLENAME_TAG = "parameter.tablename";
    public static final String KAFAK_WRITER_AIRPORT_TAG = "parameter.airport";
    public static final String KAFAK_WRITER_SYSNAME_TAG = "parameter.sysname";
}
